//package com.xingkeduo.websocket.hanler;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnError;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.ServerEndpoint;
//
//import org.springframework.stereotype.Component;
//
//import com.xingkeduo.util.ConstUtil;
//
//@Component
//@ServerEndpoint("/shop/monitor")
//public class ShopMonitorHandler {
//	/**
//	 * 建立连接
//	 *
//	 * @param session
//	 */
//	@OnOpen
//	public void onOpen(Session session) {
//
//		try {
//			System.out.println("有新连接加入！ 客户id：" + session.getId());
//			ConstUtil.MONITORS.put(session.getId(), session);
//		} catch (Throwable e) {
//			e.printStackTrace();
//			System.out.println("monitor上线的时候通知所有人发生了错误");
//		}
//	}
//
//	@OnError
//	public void onError(Session session, Throwable error) {
//		System.out.println("服务端发生了错误" + error.getMessage());
//	}
//
//	/**
//	 * 连接关闭
//	 */
//	@OnClose
//	public void onClose(Session session) {
//		try {
//			ConstUtil.MONITORS.remove(session.getId());
//		} catch (Throwable e) {
//			e.printStackTrace();
//			System.out.println("monitor下线的时候通知所有人发生了错误");
//		}
//		System.out.println("有连接关闭！ 当前在线人数" + ConstUtil.getOnlineNumber());
//	}
//
//	/**
//	 * 收到客户端的消息
//	 *
//	 * @param message
//	 *            消息
//	 * @param session
//	 *            会话
//	 */
//	@OnMessage
//	public void onMessage(String message, Session session) {
//		try {
//			System.out.println("来自客户端消息：" + message + "客户端的id是：" + session.getId());
//		} catch (Throwable e) {
//			e.printStackTrace();
//			System.out.println("发生了错误了");
//		}
//	}
//}
